/*
 * 版权：Copyright © PING AN INSURANCE (GROUP) COMPANY OF CHINA ,LTD. All Rights Reserved.
 * 项目名称：test.springcloud.stream
 * 文件名：SinkReceiver.java
 * 描述： TODO 请对当前类功能进行简单描述
 * 创建人： XIWEICHENG497
 * 创建时间：2018下午5:03:35
 * 版本：TODO 请填写版本号
 * SR/NEED单号: TODO 请填写SR或NEED单号
 * 修改人：TODO 如果是新建请忽略，如果是修改请填写修改人
 * 修改时间：TODO 如果是新建请忽略，如果是修改请填写修改时间
 * SR/NEED单号：TODO 如果是新建请忽略，如果是修改请填写SR或NEED单号
 * 修改内容：TODO 如果是新建请忽略，如果是修改请填写修改修改内容
 */
package com.xiweicheng.test.springcloud.stream;

import org.springframework.context.annotation.Configuration;
import org.springframework.integration.annotation.ServiceActivator;

import lombok.extern.slf4j.Slf4j;

/**
 * TODO〈一句话功能简述〉
 * TODO〈功能详细描述〉
 * @author XIWEICHENG497
 * @date 2018年1月23日 下午5:03:35
 * @version TODO[版本号]
 * @see   [相关类/方法]，如果需要请填写
 * @since [产品/模块版本],如果需要请填写
 */
@Slf4j
@Configuration
public class MyReceiver {

    // @StreamListener(Sink.INPUT)
    @ServiceActivator(inputChannel = MyChannel.Input)
    public void receive(Object payload) {
        log.info("Received: {}", payload);
    }
}
